package com.catmiao.rdd.operate.project;

import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;

import java.util.Arrays;
import java.util.List;

/**
 * @author ChengMiao
 * @title: Transfer_01_Map
 * @projectName spark_study
 * @description: TODO
 * @date 2024/11/25 16:27
 */
public class Rdd_Project {

    public static void main(String[] args) throws InterruptedException {

        final SparkConf conf = new SparkConf();
        conf.setAppName("appName");
        conf.setMaster("local[*]");

        final JavaSparkContext jsc = new JavaSparkContext(conf);


        /**
         * 数据分析：搜索、点击、下单、支付
         * 2019-07-17_38_6502cdc9-cf95-4b08-8854-f03a25baa917_22_2019-07-17 00:00:28_null_-1_-1_null_null_15,1,20,6,4_15,88,75_9
         *  - 2019-07-17    日期
         *  - 38            用户Id
         *  - 6502cdc9-cf95-4b08-8854-f03a25baa917  sessionId
         *  - 22    页面id
         *  - 2019-07-17 00:00:28   动作时间点
         *  - null  搜索关键字
         *  - -1    品类id
         *  - -1    产品id
         *  - null  下单的品类Id
         *  - null  下单的产品Id
         *  - 15,1,20,6,4   支付的品类id
         *  - 15,88,75      支付的产品id
         *  - 9     城市id
         */
        jsc.close();


    }
}




